package SparkStreaming_study

import org.apache.spark.SparkConf
import org.apache.spark.streaming.dstream.ReceiverInputDStream
import org.apache.spark.streaming.{Seconds, StreamingContext}

object wordCount {
  def main(args: Array[String]): Unit = {
    //  准备环境
    val sparkconf=new SparkConf().setMaster("local[*]").setAppName("统计单词")
    //  第二个参数 seconds(3)为采集数据的周期，也就是3秒采集一次数据进行处理
    val ssc=new StreamingContext(sparkconf,Seconds(3))

    //  定义数据收集器，接收数据
    val lines:ReceiverInputDStream[String]=ssc.socketTextStream("192.168.40.110",9999)







    // 这里不可以使用close()
    //  然后因为
    ssc.stop()

  }

}
